The execute service handler in __init__.py was performing all SSH I/O inline, violating the standard HA pattern where a coordinator owns I/O and callers are pure dispatchers.

Changes

coordinator.py (new)

• SshCommandCoordinator owns all SSH I/O for the integration
• async_execute(data) — connection, command execution, and error mapping
• _resolve_known_hosts(...) — moved from __init__.py

__init__.py

• async_setup_entry creates SshCommandCoordinator(hass) and stores it at hass.data[DOMAIN][entry.entry_id]
• async_unload_entry removes it
• Service handler validates input, then delegates:

# Before: inline SSH I/O
async with connect(**conn_kwargs) as conn:
    result = await conn.run(**run_kwargs)
return {CONF_OUTPUT: result.stdout, ...}

# After: delegate to coordinator
coordinator = next(iter(hass.data.get(DOMAIN, {}).values()), None)
return await coordinator.async_execute(service_call.data)

Tests

• test_async_execute.py — patches updated to ssh_command.coordinator.*; asyncSetUp now calls async_setup_entry to wire up the coordinator
• test_async_setup.py — added assertions for coordinator creation/removal
• test/test_coordinator.py (new) — unit tests for async_execute error paths and _resolve_known_hosts

• Fixes Should a coordinator be used for SSH calls? #3

💬 Send tasks to Copilot coding agent from Slack and Teams to turn conversations into code. Copilot posts an update in your thread when it's finished.